// Initial File - Paul Jack


#include "workerthreads.h"
#include "asyncmgrbase.h"
#include "messagequeue.h"
/////////////////////////////////////////////////////////////////////////////
// ReadThread
/////////////////////////////////////////////////////////////////////////////



/*!
 * ReadThread::ReadThread 
 *
 * Description: 
 *
 * @param *asyncMgr is of type AsyncMgrBase 
 *
 * @returns None
 */
ReadThread::ReadThread(AsyncMgrBase *asyncMgr)
{
    mAsyncMgr = asyncMgr;
}



/*!
 * ReadThread::work 
 *
 * Description: 
 *
 *
 * @returns bool 
 */
bool ReadThread::work()
{
    return     mAsyncMgr->readLoop();
}



/*!
 * ReadThread::initialize 
 *
 * Description: 
 *
 *
 * @returns void 
 */
void ReadThread::initialize()
{
    mAsyncMgr->initialize();
}

/////////////////////////////////////////////////////////////////////////////
// ReadBulkThread
/////////////////////////////////////////////////////////////////////////////



/*!
 * ReadBulkThread::ReadBulkThread 
 *
 * Description: 
 *
 * @param *asyncMgr is of type AsyncMgrBase 
 *
 * @returns None
 */
ReadBulkThread::ReadBulkThread(AsyncMgrBase *asyncMgr)
{
    mAsyncMgr = asyncMgr;
}



/*!
 * ReadBulkThread::work 
 *
 * Description: 
 *
 *
 * @returns bool 
 */
bool ReadBulkThread::work()
{
    return mAsyncMgr->readBulkLoop();
}



/*!
 * ReadBulkThread::initialize 
 *
 * Description: 
 *
 *
 * @returns void 
 */
void ReadBulkThread::initialize()
{
    mAsyncMgr->initialize();
}


/////////////////////////////////////////////////////////////////////////////
// WriteThread
/////////////////////////////////////////////////////////////////////////////



/*!
 * WriteThread::WriteThread 
 *
 * Description: 
 *
 * @param *asyncMgr is of type AsyncMgrBase 
 *
 * @returns None
 */
WriteThread::WriteThread(AsyncMgrBase *asyncMgr)
{
    mAsyncMgr = asyncMgr;

}



/*!
 * WriteThread::work 
 *
 * Description: 
 *
 *
 * @returns bool 
 */
bool WriteThread::work()
{
    return mAsyncMgr->writeLoop();
    
}



/*!
 * WriteThread::initialize 
 *
 * Description: 
 *
 *
 * @returns void 
 */
void WriteThread::initialize()
{
    mAsyncMgr->initialize();
}
